package com.zzx.boot.websocket.handler;

import com.zzx.boot.message.ConnectMessage;
import com.zzx.boot.message.Message;
import com.zzx.boot.serializable.CustomSerializable;
import com.zzx.boot.websocket.WebSocketServer;
import com.zzx.boot.websocket.session.WebSocketSession;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;

public class MessageHandler extends SimpleChannelInboundHandler<Message> {
    @Override
    protected void messageReceived(ChannelHandlerContext channelHandlerContext, Message message) throws Exception {
         message.send(channelHandlerContext);
        // 一对一聊天
        // 群聊

        System.out.println(message.toString());
    }


}
